package com.lwc;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.MessageProperties;

import java.io.IOException;
import java.util.HashMap;
import java.util.Map;
import java.util.Objects;
import java.util.concurrent.ConcurrentNavigableMap;
import java.util.concurrent.ConcurrentSkipListMap;
import java.util.concurrent.TimeoutException;

//生产者  向mq 投递消息
public class Productor {
    public static void main(String[] args) throws IOException, TimeoutException, InterruptedException {
//1创建连接工厂  设置连接信息
        ConnectionFactory factory=new ConnectionFactory();
factory.setHost("192.168.81.128");//连接主机
factory.setUsername("root");//默认是guest
 factory.setPassword("root");//默认是guest
factory.setPort(5672);//连接端口号
factory.setVirtualHost("erp");//虚拟主机

        //2用连接工厂创建连接
        Connection conn=factory.newConnection();

        //3创建信道
        Channel channel=conn.createChannel();

        //声明队列名称
        String queueName="confirm-async";
/**
 * queue 队列名称
 * durable 是否持久化
 *  exclusive是否独占队列   为true 信道必须是同一连接创建的
 *autodelete  是否自动删除    前提队列中灭有消息
 *arguments 向队列传递的其他参数
 *
 */
//设置参数
        Map<String, Object> map=new HashMap<>();
        //设置过期时间   所有队列中的消息ttl
             map.put("x-message-ttl",20000);
             channel.queueDeclare(queueName,true,false,false,map);
//发布消息
        channel.basicPublish("",queueName,null,"测试消息过期".getBytes());


        System.out.println("消息发送");

        //释放资源
        channel.close();
        conn.close();

    }
}
